//package com.chenwt.websocket;
//
//import org.java_websocket.WebSocket;
//import org.java_websocket.client.WebSocketClient;
//import org.java_websocket.drafts.Draft_6455;
//import org.java_websocket.handshake.ServerHandshake;
//
//import java.io.UnsupportedEncodingException;
//import java.net.URI;
//import java.net.URISyntaxException;
//import java.nio.ByteBuffer;
//import java.nio.channels.NotYetConnectedException;
//
///**
// * @class：ClientTest
// * @campany：zkzj
// * @author:chenwt
// * @date:2019-05-07 17:10
// * @description:
// */
//public class ClientTest {
//    public static WebSocketClient client;
//
//    public static void main(String[] args) throws URISyntaxException, NotYetConnectedException, UnsupportedEncodingException {
//        client = new WebSocketClient(new URI("ws://127.0.0.1/admin/websocket/app"),new Draft_6455()) {
//
//            @Override
//            public void onOpen(ServerHandshake arg0) {
//                System.out.println("打开链接");
//            }
//
//            @Override
//            public void onMessage(String arg0) {
//                System.out.println("收到消息"+arg0);
//            }
//
//            @Override
//            public void onError(Exception arg0) {
//                arg0.printStackTrace();
//                System.out.println("发生错误已关闭");
//            }
//
//            @Override
//            public void onClose(int arg0, String arg1, boolean arg2) {
//                System.out.println("链接已关闭");
//            }
//
//            @Override
//            public void onMessage(ByteBuffer bytes) {
//                try {
//                    System.out.println(new String(bytes.array(),"utf-8"));
//                } catch (UnsupportedEncodingException e) {
//                    e.printStackTrace();
//                }
//            }
//
//
//        };
//
//        client.connect();
//
//        while(!client.getReadyState().equals(WebSocket.READYSTATE.OPEN)){
//            System.out.println("还没有打开");
//        }
//        System.out.println("打开了");
//        send("hello world".getBytes("utf-8"));
//        client.send("hello world");
//    }
//
//    public static void send(byte[] bytes){
//        client.send(bytes);
//    }
//
//}
